package com.moli.iov.handle.worker.his.consumer;

import com.moli.iov.consumer.KafkaBatchConsumerServer;
import com.moli.iov.handle.worker.his.util.ConsumerCommonServer;
import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.kafka.support.Acknowledgment;

import javax.annotation.Resource;
import java.util.List;

/**
   * 登录报文处理
   * @param
   * @author lixueyong
   * @return
   */
@Slf4j
public class ConsumerLogoutHandle extends KafkaBatchConsumerServer {
    @Value("${hbase.tableName.iov.logout}")
    private  String HBASE_TABLENAME_IOV_LOGOUT;
    @Resource
    private ConsumerCommonServer consumerUtil;
    @Override
    public void manualHandle(List<ConsumerRecord<String, Object>> list, Acknowledgment acknowledgment) {
              consumerUtil.simpleCommonProcess(list,acknowledgment,HBASE_TABLENAME_IOV_LOGOUT);
    }

}



